
-- LuaTools需要PROJECT和VERSION这两个信息
PROJECT = "FX_4G_DTU"
VERSION = "0.0.1"

log.info("main", PROJECT, VERSION)

-- sys库是标配
_G.sys = require("sys")
sysplus = require("sysplus")
libnet = require "libnet"

--添加硬狗防止程序卡死，在支持的设备上启用这个功能
if wdt then
    wdt.init(9000)--初始化watchdog设置为9s
    sys.timerLoopStart(wdt.feed, 3000)--3s喂一次狗
end

if rtos.bsp() == "EC618" and pm and pm.PWK_MODE then
    pm.power(pm.PWK_MODE, false)
end

-- 全局变量 ----------------------------------------
local sys_led_pin = 27
-- local pin_assemble = {23,107,102,22,21,20,19,53,52,51,78,50,49} -- 引脚集合
local pin_assemble = {17,21,20,16,2,24,22,11,8,10,28,9,1} -- GPIO号
local LEDA = gpio.setup(sys_led_pin, 0, gpio.PULLDOWN)
local LED_dev = {}

-- libgnss库初始化
libgnss.clear() -- 清空数据,兼初始化
local gps_uart_id = 2
LED_GNSS = 24
LED_VBAT = 26
gpio.setup(LED_GNSS, 0) -- GNSS定位成功灯
gpio.setup(LED_VBAT, 0) -- 低电压警告灯
--=============================================================
-- 测试网站 https://netlab.luatos.com/ 点击 打开TCP 获取测试端口号
-- 要按实际情况修改
local host = "112.125.89.8" -- 服务器ip或者域名, 都可以的
local port = 45804          -- 服务器端口号
local is_udp = false        -- 如果是UDP, 要改成true, false就是TCP
local is_tls = false        -- 加密与否, 要看服务器的实际情况
-- 函数---------------------------------------------

-- 初始化GPIO函数
function init_gpio()
    -- 批量初始化
    for i=1, #pin_assemble do
        LED_dev[i] = gpio.setup(pin_assemble[i],0,gpio.PULLUP)
        log.info(PROJECT,"初始化GPIO IO为输出模式",i,"引脚号为：",pin_assemble[i]) -- 打印初始化信息
    end
end

-- 主函数
function main()
    local i = 0
    log.info(PROJECT,":GPIO控制程序开始！！！~~~")
    init_gpio() -- 初始化GPIO
    -- 简单演示
    log.info("imei", mobile.imei())
    log.info("imsi", mobile.imsi())
    local sn = mobile.sn()
    if sn then
        log.info("sn",   sn:toHex())
    end
    log.info("muid", mobile.muid())
    log.info("iccid", mobile.iccid())
    log.info("csq", mobile.csq())
    log.info("rssi", mobile.rssi())
    log.info("rsrq", mobile.rsrq())
    log.info("rsrp", mobile.rsrp())
    log.info("snr", mobile.snr())
    log.info("simid", mobile.simid())
    
    while 1 do
        -- 闪烁循环
        if i % 2 == 0 then
            for i=1,#pin_assemble do
                LED_dev[i](1)
            end
            -- log.info(PROJECT,"设置为高电平")
        else
            for i=1,#pin_assemble do
                LED_dev[i](0)
            end
            -- log.info(PROJECT,"设置为低电平")
        end
        
        sys.wait(1000)
        i = i + 1
    end
end

function sys_led_user()
    --开始流水灯
    local count = 0
    while 1 do
    --流水灯程序
        sys.wait(1000) --点亮时间
        -- 轮流点灯
        LEDA(count % 3 == 0 and 1 or 0)
        
        -- log.info(PROJECT, "led协程", count, rtos.bsp())
        -- log.info("LuatOS:", "https://wiki.luatos.com")
        
        count = count + 1
    end
end

function neting()
    -----------------------------
    -- 统一联网函数, 可自行删减
    ----------------------------
    if wlan and wlan.connect then
        -- wifi 联网, ESP32系列均支持, 要根据实际情况修改ssid和password!!
        local ssid = "luatos1234"
        local password = "12341234"
        log.info("wifi", ssid, password)
        -- TODO 改成自动配网
        wlan.init()
        wlan.setMode(wlan.STATION) -- 默认也是这个模式,不调用也可以
        wlan.connect(ssid, password, 1)
    elseif mobile then
        -- EC618系列, 如Air780E/Air600E/Air700E
        -- mobile.simid(2) -- 自动切换SIM卡, 按需启用
        -- 模块默认会自动联网, 无需额外的操作
    elseif w5500 then
        -- w5500 以太网
        w5500.init(spi.HSPI_0, 24000000, pin.PC14, pin.PC01, pin.PC00)
        w5500.config() --默认是DHCP模式
        w5500.bind(socket.ETH0)
    elseif socket then
        -- 适配了socket库也OK, 就当1秒联网吧
        sys.timerStart(sys.publish, 1000, "IP_READY")
    else
        -- 其他不认识的bsp, 循环提示一下吧
        while 1 do
            sys.wait(1000)
            log.info("bsp", "本bsp可能未适配网络层, 请查证")
        end
    end
    -- 默认都等到联网成功
    sys.waitUntil("IP_READY")
    sys.publish("net_ready")
end

function sockettask(d1Name, txqueue, rxtopic)
    -- 打印准备连接的服务器信息
    log.info("socket", host, port, is_udp and "UDP" or "TCP", is_tls and "TLS" or "RAW")

    -- 准备好所需要的接收缓冲区
    local rx_buff = zbuff.create(1024)
    local netc = socket.create(nil, d1Name)
    socket.config(netc, nil, is_udp, is_tls)
    log.info("任务id", d1Name)

    while true do
        -- 连接服务器, 15秒超时
        log.info("socket", "开始连接服务器")
        sysplus.cleanMsg(d1Name)
        local result = libnet.connect(d1Name, 15000, netc, host, port)
        if result then
			log.info("socket", "服务器连上了")
			libnet.tx(d1Name, 0, netc, "helloworld")
        else
            log.info("socket", "服务器没连上了!!!")
		end
		while result do
            -- 连接成功之后, 先尝试接收
            -- log.info("socket", "调用rx接收数据")
			local succ, param = socket.rx(netc, rx_buff)
			if not succ then
				log.info("服务器断开了", succ, param, ip, port)
				break
			end
            -- 如果服务器有下发数据, used()就必然大于0, 进行处理
			if rx_buff:used() > 0 then
				log.info("socket", "收到服务器数据，长度", rx_buff:used())
                local data = rx_buff:query() -- 获取数据
                sys.publish(rxtopic, "downlink", data)
				rx_buff:del()
			end
            -- log.info("libnet", "调用wait开始等待消息")
            -- 等待事件, 例如: 服务器下发数据, 有数据准备上报, 服务器断开连接
			result, param, param2 = libnet.wait(d1Name, 15000, netc)
            log.info("libnet", "wait", result, param, param2)
			if not result then
                -- 网络异常了, 那就断开了, 执行清理工作
				log.info("socket", "服务器断开了", result, param)
				break
            elseif #txqueue > 0 then
                -- 有待上报的数据,处理之
                while #txqueue > 0 do
                    local data = table.remove(txqueue, 1)
                    if not data then
                        break
                    end
                    result,param = libnet.tx(d1Name, 15000, netc,data)
                    log.info("libnet", "发送数据的结果", result, param)
                    if not result then
                        log.info("socket", "数据发送异常", result, param)
                        break
                    end
                end
            end
            -- 循环尾部, 继续下一轮循环
		end
        -- 能到这里, 要么服务器断开连接, 要么上报(tx)失败, 或者是主动退出
		libnet.close(d1Name, 5000, netc)
		-- log.info(rtos.meminfo("sys"))
		sys.wait(30000) -- 这是重连时长, 自行调整
    end
end

-- 客户端协程
function socket_client()
    -- 等待联网
    sys.waitUntil("net_ready")

    socket.sntp()

    -- 开始正在的逻辑, 发起socket链接,等待数据/上报心跳
    local taskName = "sc"
    local topic = taskName .. "_txrx"
    log.info("topic", topic)
    local txqueue = {}
    sysplus.taskInitEx(sockettask, taskName, netCB, taskName, txqueue, topic)
    while 1 do
        local result, tp, data = sys.waitUntil(topic, 30000)
        log.info("event", result, tp, data)
        if not result then
            -- 等很久了,没数据上传/下发, 发个日期心跳包吧
            table.insert(txqueue, string.char(0))
            sys_send(taskName, socket.EVENT, 0)
        elseif tp == "uplink" then
            -- 上行数据, 主动上报的数据,那就发送呀
            table.insert(txqueue, data)
            sys_send(taskName, socket.EVENT, 0)
        elseif tp == "downlink" then
            -- 下行数据,接收的数据, 从ipv6task来的
            -- 其他代码可以通过 sys.publish()
            log.info("socket", "收到下发的数据了", #data)
        end
    end
end

-- gnss协程
function gnss_init()
    uart.setup(gps_uart_id, 115200)
    libgnss.bind(gps_uart_id)
    libgnss.debug(true)

    while 1 do
        log.info("~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~")
        log.info("RMC", json.encode(libgnss.getRmc(2) or {}, "7f"))
        log.info("INT", libgnss.getIntLocation())
        log.info("GGA", libgnss.getGga(3))
        log.info("GLL", json.encode(libgnss.getGll(2) or {}, "7f"))
        log.info("GSA", json.encode(libgnss.getGsa(2) or {}, "7f"))
        log.info("GSV", json.encode(libgnss.getGsv(2) or {}, "7f"))
        log.info("VTG", json.encode(libgnss.getVtg(2) or {}, "7f"))
        log.info("ZDA", json.encode(libgnss.getZda(2) or {}, "7f"))
        -- log.info("RMC", libgnss.getRmc())
        -- log.info("INT", libgnss.getIntLocation())
        -- log.info("GGA", libgnss.getGga(3))
        -- log.info("GLL", libgnss.getGll(2))
        -- log.info("GSA", libgnss.getGsa(2))
        -- log.info("GSV", libgnss.getGsv(2))
        -- log.info("VTG", libgnss.getVtg(2))
        -- log.info("ZDA", libgnss.getZda(2))


        local onoff = libgnss.isFix() and 1 or 0
        log.info("GNSS", "定位状态：", onoff)
        if onoff == 1 then
            locStr = libgnss.locStr()
            log.info("gnss", "locStr", locStr)
        end
        -- libgnss.clear()

        sys.wait(3000)
    end
    
end

-- 主代码逻辑------------------------------------------
sys.taskInit(main)
sys.taskInit(sys_led_user)
-- sys.taskInit(neting)
-- sys.taskInit(socket_client)
-- sys.taskInit(function()
--     sys.wait(5000)
--     while 1 do
--         sys.publish("sc_txrx", "uplink", os.date())
--         sys.wait(3000)
--     end
-- end)
sys.taskInit(gnss_init)
-- ------------------------------------------
-- API文档 https://wiki.luatos.com/api/gpio.html

-- 用户代码已结束---------------------------------------------
sys.run()
-- sys.run()之后后面不要加任何语句!!!!!
